package cn.z2huo.demo.hello.kafka.service.api;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.List;

/**
 * <p>kafka 消息持久化服务
 *
 * @author z2huo
 */

public interface KafkaFailService {

    boolean onFail(ConsumerRecord<String, String> record, String kafkaSouce);

    boolean onFail(List<ConsumerRecord<String, String>> records, String kafkaSouce);

}
